package com.lzq.mq.client.consumer;

import java.util.List;

/**
 * 数据消费监听器接口
 */
public interface MessageConsumeListener {


    /**
     * 消费处理函数
     */
    ConsumeResult consume(List<ConsumeMessage> consumeMessages);
}
